const { from } = require('rxjs')

const observable = from([1,2,3])
const subscription = observable.subscribe(x => console.log(x))
subscription.unsubscribe()